package com.xs.sendto;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

//@Component
public class App1 {

	private static Logger logger = LoggerFactory.getLogger(App1.class);

/*	@StreamListener(Processor.INPUT)
	@SendTo(Processor.OUTPUT)*/
	@StreamListener("A1")
	@SendTo("B1")
	public String receiveMethod(Device device) {
		logger.info("App1 ： " + device);
		return "Hello App2";
	}

}
